/**
 * @description: 管道流，将可读流数据写入到可写流中
 * @param {*} rs 可读流
 * @param {*} ws 可写流
 * @return {*}
 */ 
function pipeStream(rs, ws) {
  return new Promise((resolve, reject) => {
    rs.pipe(ws).on('finish', resolve).on('error', reject)
  })
}
module.exports = {
  pipeStream
}
